package com.bnz.producer;

import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class Producer01 {
    //映入rabbitmq
    @Autowired
    private RabbitTemplate rabbitTemplate;
    /**
     * 发送直连消息(direct)
     */
    @Test
    public void test01(){
        //有队列名+
        rabbitTemplate.convertAndSend("bnz","正在发送direct消息！");

    }

    /**
     * 发送分裂消息(fanout)  ---三个参数，两个参数不行
     * 调用convertAndSend发送方法
     */
    @Test
    public void test02(){
        rabbitTemplate.convertAndSend("bnz-school","","各校区请注意，放假时间为8月88号！");
    }

    /**
     *  发送topic消息 （以goods开头消息）
     */
    @Test
    public void test03(){
        rabbitTemplate.convertAndSend("fourbooks","goods.#","正在发送以goods开头的消息！");
    }

    /**
     *发送topic消息 （以log结尾消息）
     */
    @Test
    public void test04(){
        rabbitTemplate.convertAndSend("fourbooks","#.log","正在发送以log结尾的消息！");
    }

    /**
     *  发送topic消息 （以goods开头以log结尾消息）
     */
    @Test
    public void test05(){
        rabbitTemplate.convertAndSend("fourbooks","goods.log","正在发送以goods开头以log结尾的消息！");
    }

}

